a7f7c4af06bb668e937bbae51c20ec585e664726,services/ctrip-service/src/main/java/com/ctrip/xpipe/service/migration/CredisMigrationPublishService.java,CredisMigrationPublishService,doMigrationPublish,#String#String#List#,28
Before Change
@Override
public MigrationPublishResult doMigrationPublish(String clusterName, String primaryDcName, List<InetSocketAddress> newMasters) {
logger.info("[doMigrationPublish]Cluster:{}, NewPrimaryDc:{} -> ConvertedDcName:{} , NewMasters:{}", clusterName, primaryDcName,convertDcName(primaryDcName), newMasters);
return restOperations.postForObject(
CREDIS_SERVICE.MIGRATION_PUBLISH.getRealPath(MigrationPublishServiceConfig.INSTANCE.getCredisServiceAddress()),
newMasters, MigrationPublishResult.class, clusterName, convertDcName(primaryDcName));
}
@Override
After Change
@Override
public MigrationPublishResult doMigrationPublish(String clusterName, String primaryDcName, List<InetSocketAddress> newMasters) {
logger.info("[doMigrationPublish]Cluster:{}, NewPrimaryDc:{} -> ConvertedDcName:{} , NewMasters:{}", clusterName, primaryDcName,convertDcName(primaryDcName), newMasters);
MigrationPublishResult res = restOperations.postForObject(
CREDIS_SERVICE.MIGRATION_PUBLISH.getRealPath(MigrationPublishServiceConfig.INSTANCE.getCredisServiceAddress()),
newMasters, MigrationPublishResult.class, clusterName, convertDcName(primaryDcName));
res.setPublishAddress(CREDIS_SERVICE.MIGRATION_PUBLISH.getRealPath(MigrationPublishServiceConfig.INSTANCE.getCredisServiceAddress()));
res.setClusterName(clusterName);
res.setPrimaryDcName(primaryDcName);
res.setNewMasters(newMasters);
return res;
}
@Override